package cn.edu.lcu.cs.javaprogramming.thread.producer_consumer.piped;

import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * @author ling
 * @date 2022/5/30 23:28
 */
public class Process {
    public static void main(String[] args) throws IOException {
        // 创建生产者、消费者
        Producer producer = new Producer();
        Consumer consumer = new Consumer();
        // 把生产者的管道输出流与消费者的管道输入流连接在一起
        // 生产者与消费者是一对一的关系
        producer.getSink().connect(consumer.getSource());

        // 一个生产，一个消费，成双配对，否则会出错。
        new Thread(producer, "生产者1").start();
        //new Thread(producer, "生产者2").start();
        //new Thread(producer, "生产者3").start();
        new Thread(consumer, "消费者1").start();
    }
}
